package com.whut.customer.test;

import org.junit.Test;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;

/**
 * Jedis测试
 */
public class JedisDemo {
    @Test
    public void Demo1(){
        // 1.设置IP地址和端口
        Jedis jedis=new Jedis("127.0.0.1",6379);
        jedis.auth("123456");
        // 2.保存数据
        jedis.set("name","fd");
        // 3.获取数据
        String value=jedis.get("name");
        System.out.println(value);
        jedis.close();
    }

    /**
     * 连接池方式
     */
    @Test
    public void Demo2(){
        // 1.获取连接池配置的对象
        JedisPoolConfig config=new JedisPoolConfig();
        // 2.设置最大链接数
        config.setMaxTotal(30);
        // 3.设置最大空闲链接数
        config.setMaxIdle(10);

        // 获得连接池
        JedisPool jedisPool=new JedisPool(config,"127.0.0.1",6379,3000,"123456");
        // 获得核心对象
        Jedis jedis=null;
        try{
            // 通过连接池获得链接
            jedis = jedisPool.getResource();
            // 设置数据
            jedis.set("name","fd");
            // 获取数据
            String value2=jedis.get("name");
            System.out.println(value2);
        }
        catch(Exception e){
            e.printStackTrace();
        }
        finally {
            // 释放资源
            if(jedis!=null)
                jedis.close();
            if(jedisPool!=null)
                jedisPool.close();
        }

    }

}
